Node / mirrors / MeshChatX / files / tests / backend / eect / packs / test_messaging_tools_pack.py

Displaying Raw • Download

T8b949e# SPDX-License-Identifier: 0BSD

T8b949e"""MessagingToolsPack: sieve, forwarder, and blocklist accept/reject oracles."""

Tff7b72from T7ee787__future__ Tff7b72import Te6edf3annotations

Tff7b72import T7ee787asyncio

Tff7b72from T7ee787unittestT7ee787.T7ee787mock Tff7b72import Te6edf3AsyncMockTb4b4b4, Te6edf3MagicMockTb4b4b4, Te6edf3patch

Tff7b72import T7ee787pytest

Tff7b72from T7ee787meshchatxT7ee787.T7ee787srcT7ee787.T7ee787backendT7ee787.T7ee787lxmf_sieve Tff7b72import Tb4b4b4(

Te6edf3first_matching_lxmf_sieve_ruleTb4b4b4,

Te6edf3normalize_lxmf_sieve_filtersTb4b4b4,

Tb4b4b4)

Tff7b72from T7ee787meshchatxT7ee787.T7ee787srcT7ee787.T7ee787backendT7ee787.T7ee787message_blocklist Tff7b72import Tb4b4b4(

Te6edf3first_matching_blocklist_entryTb4b4b4,

Te6edf3normalize_message_blocklistTb4b4b4,

Tb4b4b4)

Tff7b72from T7ee787testsT7ee787.T7ee787backendT7ee787.T7ee787eectT7ee787.T7ee787harness Tff7b72import Te6edf3eect_scenario

Tff7b72from T7ee787testsT7ee787.T7ee787backendT7ee787.T7ee787lxmf_tools_support Tff7b72import Tb4b4b4(

Te6edf3LOCAL_LXMFTb4b4b4,

Te6edf3PEER_ALIASTb4b4b4,

Te6edf3PEER_FORWARD_TOTb4b4b4,

Te6edf3PEER_OTHERTb4b4b4,

Te6edf3PEER_SPAMMERTb4b4b4,

Te6edf3make_inbound_lxmfTb4b4b4,

Te6edf3prepare_messaging_appTb4b4b4,

Tb4b4b4)

Te6edf3pytestmark Tff7b72= Te6edf3pytestTff7b72.Td2a8ffmarkTff7b72.Td2a8ffeect

Tff7b72def Td2a8ff_run_asyncTb4b4b4(Te6edf3coroTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3asyncioTff7b72.Td2a8ffiscoroutineTb4b4b4(Te6edf3coroTb4b4b4)Tb4b4b4:

Te6edf3asyncioTff7b72.Td2a8ffrunTb4b4b4(Te6edf3coroTb4b4b4)

Tff7b72def Td2a8fftest_eect_sieve_first_match_and_suppressTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72with Te6edf3eect_scenarioTb4b4b4(Ta5d6ff"Ta5d6ffmessaging.sieve.first_matchTa5d6ff"Tb4b4b4) Tff7b72as Tb4b4b4(Te6edf3_sTb4b4b4, Te6edf3_seedTb4b4b4, Te6edf3rngTb4b4b4)Tb4b4b4:

Te6edf3term Tff7b72= Ta5d6fffTa5d6ff"Ta5d6fftokTffd700{Te6edf3rngTff7b72.Td2a8ffrandintTb4b4b4(T79c0ff10Tb4b4b4, T79c0ff99Tb4b4b4)Tffd700}Ta5d6ff"

Te6edf3rules Tff7b72= Te6edf3normalize_lxmf_sieve_filtersTb4b4b4(

Tb4b4b4[

Tb4b4b4{Ta5d6ff"Ta5d6ffactionTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6ffignoreTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6fftermsTa5d6ff"Tb4b4b4: Tb4b4b4[Te6edf3termTb4b4b4]Tb4b4b4, Ta5d6ff"Ta5d6ffenabledTa5d6ff"Tb4b4b4: Tff7b72FalseTb4b4b4}Tb4b4b4,

Tb4b4b4{

Ta5d6ff"Ta5d6ffactionTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6ffhideTa5d6ff"Tb4b4b4,

Ta5d6ff"Ta5d6fftermsTa5d6ff"Tb4b4b4: Tb4b4b4[Te6edf3termTb4b4b4]Tb4b4b4,

Ta5d6ff"Ta5d6ffmatch_peer_fieldsTa5d6ff"Tb4b4b4: Tff7b72FalseTb4b4b4,

Ta5d6ff"Ta5d6ffmatch_messageTa5d6ff"Tb4b4b4: Tff7b72TrueTb4b4b4,

Tb4b4b4}Tb4b4b4,

Tb4b4b4]Tb4b4b4,

Tb4b4b4)

Te6edf3hay Tff7b72= Ta5d6fffTa5d6ff"Ta5d6ffbody Tffd700{Te6edf3termTffd700}Ta5d6ff endTa5d6ff"

Te6edf3got Tff7b72= Te6edf3first_matching_lxmf_sieve_ruleTb4b4b4(

Te6edf3rulesTb4b4b4,

Ta5d6ff"Ta5d6ffpeerTa5d6ff"Tb4b4b4,

Te6edf3message_haystackTff7b72=Te6edf3hayTb4b4b4,

Tb4b4b4)

Tff7b72assert Te6edf3got Tff7b72is Tff7b72not Tff7b72None

Tff7b72assert Te6edf3gotTb4b4b4[Ta5d6ff"Ta5d6ffactionTa5d6ff"Tb4b4b4] Tff7b72== Ta5d6ff"Ta5d6ffhideTa5d6ff"

Tff7b72def Td2a8fftest_eect_forwarder_source_filterTb4b4b4(Te6edf3mock_appTb4b4b4)Tb4b4b4:

Tff7b72with Te6edf3eect_scenarioTb4b4b4(Ta5d6ff"Ta5d6ffmessaging.forwarder.source_filterTa5d6ff"Tb4b4b4) Tff7b72as Tb4b4b4(Te6edf3_sTb4b4b4, Te6edf3_seedTb4b4b4, Te6edf3_rngTb4b4b4)Tb4b4b4:

Te6edf3app Tff7b72= Te6edf3prepare_messaging_appTb4b4b4(Te6edf3mock_appTb4b4b4)

Te6edf3appTff7b72.Td2a8ffcurrent_contextTff7b72.Td2a8ffforwarding_manager Tff7b72= Te6edf3MagicMockTb4b4b4(Tb4b4b4)

Te6edf3appTff7b72.Td2a8ffcurrent_contextTff7b72.Td2a8ffforwarding_managerTff7b72.Td2a8ffget_or_create_mappingTff7b72.Td2a8ffreturn_value Tff7b72= Tb4b4b4{

Ta5d6ff"Ta5d6ffalias_hashTa5d6ff"Tb4b4b4: Te6edf3PEER_ALIASTb4b4b4,

Tb4b4b4}

Te6edf3appTff7b72.Td2a8ffdatabaseTff7b72.Td2a8ffmiscTff7b72.Td2a8ffcreate_forwarding_ruleTb4b4b4(

Te6edf3identity_hashTff7b72=Te6edf3LOCAL_LXMFTb4b4b4,

Te6edf3forward_to_hashTff7b72=Te6edf3PEER_FORWARD_TOTb4b4b4,

Te6edf3source_filter_hashTff7b72=Te6edf3PEER_OTHERTb4b4b4,

Te6edf3is_activeTff7b72=Tff7b72TrueTb4b4b4,

Te6edf3nameTff7b72=Ta5d6ff"Ta5d6fffilterTa5d6ff"Tb4b4b4,

Tb4b4b4)

Te6edf3appTff7b72.Td2a8ffsend_message Tff7b72= Te6edf3AsyncMockTb4b4b4(Tb4b4b4)

Te6edf3miss Tff7b72= Te6edf3make_inbound_lxmfTb4b4b4(

Te6edf3source_hashTff7b72=Te6edf3PEER_SPAMMERTb4b4b4,

Te6edf3destination_hashTff7b72=Te6edf3LOCAL_LXMFTb4b4b4,

Te6edf3contentTff7b72=Ta5d6ff"Ta5d6ffmissTa5d6ff"Tb4b4b4,

Tb4b4b4)

Tff7b72with Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffmeshchatx.meshchat.AsyncUtils.run_asyncTa5d6ff"Tb4b4b4, Te6edf3side_effectTff7b72=Te6edf3_run_asyncTb4b4b4)Tb4b4b4:

Te6edf3appTff7b72.Td2a8ffhandle_forwardingTb4b4b4(Te6edf3missTb4b4b4, Te6edf3contextTff7b72=Te6edf3appTff7b72.Td2a8ffcurrent_contextTb4b4b4)

Te6edf3appTff7b72.Td2a8ffsend_messageTff7b72.Td2a8ffassert_not_calledTb4b4b4(Tb4b4b4)

Te6edf3hit Tff7b72= Te6edf3make_inbound_lxmfTb4b4b4(

Te6edf3source_hashTff7b72=Te6edf3PEER_OTHERTb4b4b4,

Te6edf3destination_hashTff7b72=Te6edf3LOCAL_LXMFTb4b4b4,

Te6edf3contentTff7b72=Ta5d6ff"Ta5d6ffhitTa5d6ff"Tb4b4b4,

Tb4b4b4)

Tff7b72with Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffmeshchatx.meshchat.AsyncUtils.run_asyncTa5d6ff"Tb4b4b4, Te6edf3side_effectTff7b72=Te6edf3_run_asyncTb4b4b4)Tb4b4b4:

Te6edf3appTff7b72.Td2a8ffhandle_forwardingTb4b4b4(Te6edf3hitTb4b4b4, Te6edf3contextTff7b72=Te6edf3appTff7b72.Td2a8ffcurrent_contextTb4b4b4)

Te6edf3appTff7b72.Td2a8ffsend_messageTff7b72.Td2a8ffassert_awaited_onceTb4b4b4(Tb4b4b4)

Tff7b72assert Te6edf3appTff7b72.Td2a8ffsend_messageTff7b72.Td2a8ffawait_argsTff7b72.Td2a8ffkwargsTb4b4b4[Ta5d6ff"Ta5d6ffdestination_hashTa5d6ff"Tb4b4b4] Tff7b72== Te6edf3PEER_FORWARD_TO

Tff7b72def Td2a8fftest_eect_blocklist_non_contacts_onlyTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72with Te6edf3eect_scenarioTb4b4b4(Ta5d6ff"Ta5d6ffmessaging.blocklist.non_contactsTa5d6ff"Tb4b4b4) Tff7b72as Tb4b4b4(Te6edf3_sTb4b4b4, Te6edf3_seedTb4b4b4, Te6edf3_rngTb4b4b4)Tb4b4b4:

Te6edf3blocklist Tff7b72= Te6edf3normalize_message_blocklistTb4b4b4(

Tb4b4b4{

Ta5d6ff"Ta5d6ffscopeTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6ffnon_contactsTa5d6ff"Tb4b4b4,

Ta5d6ff"Ta5d6ffmatch_messageTa5d6ff"Tb4b4b4: Tff7b72TrueTb4b4b4,

Ta5d6ff"Ta5d6ffentriesTa5d6ff"Tb4b4b4: Tb4b4b4[Tb4b4b4{Ta5d6ff"Ta5d6fftextTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6ffbuy nowTa5d6ff"Tb4b4b4}Tb4b4b4]Tb4b4b4,

Tb4b4b4}Tb4b4b4,

Tb4b4b4)

Te6edf3contact Tff7b72= Te6edf3first_matching_blocklist_entryTb4b4b4(

Te6edf3blocklistTb4b4b4,

Ta5d6ff"Ta5d6fffriendTa5d6ff"Tb4b4b4,

Te6edf3is_contactTff7b72=Tff7b72TrueTb4b4b4,

Te6edf3message_haystackTff7b72=Ta5d6ff"Ta5d6ffbuy nowTa5d6ff"Tb4b4b4,

Tb4b4b4)

Te6edf3stranger Tff7b72= Te6edf3first_matching_blocklist_entryTb4b4b4(

Te6edf3blocklistTb4b4b4,

Ta5d6ff"Ta5d6ffstrangerTa5d6ff"Tb4b4b4,

Te6edf3is_contactTff7b72=Tff7b72FalseTb4b4b4,

Te6edf3message_haystackTff7b72=Ta5d6ff"Ta5d6ffbuy nowTa5d6ff"Tb4b4b4,

Tb4b4b4)

Tff7b72assert Te6edf3contact Tff7b72is Tff7b72None

Tff7b72assert Te6edf3stranger Tff7b72is Tff7b72not Tff7b72None

Tff7b72assert Te6edf3strangerTb4b4b4[Ta5d6ff"Ta5d6fftextTa5d6ff"Tb4b4b4] Tff7b72== Ta5d6ff"Ta5d6ffbuy nowTa5d6ff"